package com.heima.stream.listener;
import org.apache.kafka.streams.kstream.KStream;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
/**
 * @BelongsProject: heima-leadnews
 * @BelongsPackage: com.heima.stream.listener
 * @Author: wangjian
 * @CreateTime: 2022-07-08  17:35
 * @Description: TODO
 * @Version: 1.0
 */

public interface WordCountProcessor {

    @Input("WordCountSource")
    KStream<String, String> input();
    @Output("WordCountResult")
    KStream<String, String> output();
}
